package org.example.mq.consumer;


import com.aliyun.openservices.ons.api.MessageListener;
import com.aliyun.openservices.ons.api.PropertyValueConst;

/**
 * @description: MQ消费者接口
 * @author: wuwenxue
 * @date: 2023-07-13 10:11
 */
public interface MessageListenerConsumer extends MessageListener {

    default String getMessageModel() {
        return PropertyValueConst.CLUSTERING;
    }

    String getTopic();

    String getGid();

    default String getTag() {
        return "*";
    }

    default String getSQL92() {
        return null;
    }

    void setGid(String gid);
}
